dc52e318137e6e80391578206f8537b9839b499f,tests/perf/org/jgroups/tests/perf/Test.java,Test,handleData,#Object#number#,337
Before Change
if(all_received)
return;
if(start == 0) {
start=System.currentTimeMillis();
}
num_msgs_received++;
After Change
if(all_received)
return;
if(start == 0) {
start=last_interval=System.currentTimeMillis();
}
num_msgs_received++;
num_bytes_received+=num_bytes;
if(num_msgs_received >= num_msgs_expected) {
if(stop == 0) {
stop=System.currentTimeMillis();
}
all_received=true;
}
if(num_msgs_received % log_interval == 0) {
long curr=System.currentTimeMillis();
long diff=curr - last_interval;
last_interval=curr;
double msgs_sec=log_interval / (diff / 1000.0);
System.out.println(new StringBuilder("-- received ").append(num_msgs_received).append(" messages")